#! /usr/bin/python3

import pymysql

# 打开数据库连接
db = pymysql.connect('localhost', 'root', '123456', 'testdb')

# 使用 cursor() 方法创建一个游标对象cursor
cursor = db.cursor()

# SQL语句
sql = '''insert into employee(first_name,
         last_name, age, sex, income)
         values("Mac", "Mohan", 20, "M", 2000)'''

try:
   # 执行sql语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # 如果发生错误则回滚
   db.rollback()
# 关闭数据库连接
db.close()
